'use strict';

const Controller = require('egg').Controller;
// const {ObjectId} = require('mongodb')
class CollectedController extends Controller {
  async index() {
    const { ctx } = this;
    var {id,collected} = ctx.request.body
    collected = (collected == "true") ? true : false
    const db = this.app.mongodb
    await ctx.service.movie.collectedMovie({id,collected})
    const res = await ctx.service.movie.getMovieDetailOrSearch({id:id})
    console.log(res[0]);
    const item = res[0]
    try{
      if (collected) {
        await db.collection("user").insertOne(item)
        ctx.body = {
          status:200,
          msg:"收藏成功"
        }
      }else{
        await db.collection("user").deleteOne({_id:id})
        ctx.body = {
          status:200,
          msg:"取消收藏"
        }
      }
    }catch(err){
      this.app.logger.error(err)
      ctx.body = {
        status:400,
        msg:"数据库中已经存在，请勿重复添加"
      }
    }
  }
}

module.exports = CollectedController;
